package com.study.demo01.listener;

import com.study.demo01.dto.User;

import javax.servlet.ServletContext;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.annotation.WebListener;
import javax.servlet.http.*;
import java.util.ArrayList;
import java.util.List;

/**
 *在线用户监听器
 */
@WebListener()
public class OnLineListener implements ServletContextListener,
        HttpSessionListener, HttpSessionAttributeListener {
    //创建一个application变量
    ServletContext  application = null;

    // Public constructor is required by servlet spec
    public OnLineListener() {
    }

    //监听服务器启动的method
    public void contextInitialized(ServletContextEvent sce) {

        System.out.println("------------服务器启动了---------------");
        //创建一个List<user>,并把该list存到application中
        List<User> users = new ArrayList<>();
        application =  sce.getServletContext();
        //创建一个onlineUser来存在线用户
        List<String> onlineUser = new ArrayList<>();
        application.setAttribute("users",users);
        application.setAttribute("onlineUser",onlineUser);
    }

    public void contextDestroyed(ServletContextEvent sce) {
        System.out.println("--------------服务器关闭了----------------");
    }

    // HttpSessionListener implementation
    //session是基于服务器端创建的。当一个浏览器访问服务器就会创建一个唯一session
    public void sessionCreated(HttpSessionEvent se) {
        System.out.println("-----session被创建了-----------");
        /**
         * 可以统计当前有多少人连接我们的服务器。(统计在线访问人数)
         */
    }

    public void sessionDestroyed(HttpSessionEvent se) {
        /* Session is destroyed. */
        System.out.println("--------session被销毁了------------");
        /**
         * 可以统计当前有多少人连接我们的服务器。(统计在线访问人数)
         */
    }

   /*
      attributeAdded()方法:监听session执行setAttr()时触发
      统计登录到该系统的用户
    */
    public void attributeAdded(HttpSessionBindingEvent sbe) {
        System.out.println("-----session设值----"+sbe.getName()+","+sbe.getValue());
        User user = (User) sbe.getValue();
        //创建一个list来记录在线用户
        HttpSession session = sbe.getSession();
        application  = session.getServletContext();
        //先从缓存application域中拿到  onlineUser
        List<String> onlineUser = (List<String>) application.getAttribute("onlineUser");
        if(onlineUser.indexOf(user.getUserName())==-1){//新增加的userName在onlineUser中不存在
            onlineUser.add(user.getUserName());
            //存储到application中
            application.setAttribute("onlineUser",onlineUser);
        }
    }

    /**
     * attributeRemoved方法：监听session.removeAttr(key,val)
     * 当用户退出时，则注销，并且更新在线用户数量与列表
     */
    public void attributeRemoved(HttpSessionBindingEvent sbe) {
        System.out.println("-----session销毁----"+sbe.getName()+","+sbe.getValue());
        //创建一个list来记录在线用户
        HttpSession session = sbe.getSession();
        application  = session.getServletContext();
        User user = (User) sbe.getValue();

        //先从缓存application域中拿到  onlineUser
        List<String> onlineUser = (List<String>) application.getAttribute("onlineUser");
        onlineUser.remove(user.getUserName());
        application.setAttribute("onlineUser",onlineUser);
    }

    public void attributeReplaced(HttpSessionBindingEvent sbe) {

    }
}
